# handlers.py（你可以专门建个 handler 模块来写不同处理逻辑）
from utils.logger import logger

def handle_message(msg):
    logger.info(f"📩 Received message: topic={msg.topic()} partition={msg.partition()} offset={msg.offset()} value={msg.value().decode('utf-8')}")
    # 保存数据库 / 发告警 / 写文件 / 存 Redis ...